package com.tom.architect.party3.day31;

// 观察者。
public interface Observer<T> {
    void onSubscribe();
    void onNext(T item) throws Exception;

    void onError(Throwable e);

    void onComplete();
}
